package Flink.function;

import Flink.bean.WaterSensor;
import org.apache.flink.api.common.functions.FilterFunction;

public class UserFilter implements FilterFunction<WaterSensor> {

    @Override
    public boolean filter(WaterSensor value) throws Exception {
        return value.getVc() == 1;
    }
}
